package com.my.study.producer.service;

import org.apache.rocketmq.client.producer.SendCallback;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.client.producer.TransactionSendResult;
import org.springframework.messaging.Message;

public interface RocketMqSendService {

    SendResult syncSend(String topic, Object object);

    void asyncSend(String topic,Object object,SendCallback sendCallback);

    void asyncSendHandlerErrorData(String topic,Object object);

    TransactionSendResult sendMessageInTransaction(String topic, Message message);
}
